package com.example.yckjbigdataflink.utils;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;

public class HBaseConfigurationUtil {
    public static Configuration getHBaseConfiguration(String zkQuorum) {
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", zkQuorum);
        conf.set("hbase.zookeeper.property.clientPort", "2181");
        // Kerberos相关参数可以在这里也设置
        return conf;
    }
}

